package com.zhiyou.springcloud.streamhello;


import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;

/**
 * @author by zhouyanchao
 * Created on 2018/3/1.
 * Descr:用于接收来自RabbitMQ消息的消费者SinkReceiver
 */
@EnableBinding(Sink.class)
public class SinkReceiver {

	private static Logger logger = LoggerFactory.getLogger(SinkReceiver.class);

	@StreamListener(Sink.INPUT)
	public void receive(Object payload) {
		logger.info("Received: " + payload);
	}
}
